welo git mirrors
Commit 523f24e2a42e169b40d7b67a1ecb113d19e35e6b
Parents : 1bcb88b
Author : welo | main nixos computer <empty@empty.com>
Date : 2026-07-04T10:07:53+01:00
more debug printing
Changes
Diff
diff --git a/src/relay.rs b/src/relay.rs
index 210bc02..2cb7719 100644
--- a/src/relay.rs
+++ b/src/relay.rs
@@ -129,10 +129,14 @@ pub async fn relay_bidirectional_udp(
if let Err(e) = socket1.send_to(data,target).await {
warn!("[{}] UDP write error: {}", sid, e);
break;
+ } else {
+ println!("sent packet")
}
}
Err(e) => {
-
+ debug!("[{}] UDP read error: {}", sid, e);
+ break
+
}
};
@@ -175,9 +179,9 @@ pub async fn relay_bidirectional_udp(
}
};
tokio::select! {
- _ = udp_to_rns => {},
- _ = rns_to_udp => {},
- _ = break_connection_tcp_check => {},
+ _ = udp_to_rns => {println!("udp end")},
+ _ = rns_to_udp => {println!("rns end")},
+ _ = break_connection_tcp_check => {println!("tcp end")},
}
mux.send(FrameType::Close, sid, Vec::new());
diff --git a/src/server.rs b/src/server.rs
index 6685c2f..7207a0d 100644
--- a/src/server.rs
+++ b/src/server.rs
@@ -224,7 +224,7 @@ async fn handle_server_session_tcp(
// Data relay (shared implementation)
relay_bidirectional_tcp(sid, stream, mux, session_rx).await;
- info!("[{}] Closed", sid);
+ info!("[{}] TCP Closed", sid);
}
/// Handle a single proxied TCP session on the server side.
@@ -257,6 +257,6 @@ async fn handle_server_session_udp(
// Data relay (shared implementation)
relay_bidirectional_udp(sid, socket, None, mux, session_rx).await;
- info!("[{}] Closed", sid);
+ info!("[{}] UDP Closed", sid);
}
Served by rngit 1.4.2 - Generated in 0.07s